/**
 * Date:2021年3月15日 上午10:24:47
 * Copyright (c) 2021, www.bwbroad.com All Rights Reserved
 */

package com.app.rabbit;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

import com.app.producer.vo.Demo;

/**
 * Description: 参考 <br/>
 * https://blog.csdn.net/qq_36357242/article/details/107664806 <br/>
 * https://blog.csdn.net/qq_36357242/article/details/107682005 <br/>
 * Date:2021年3月15日 上午10:24:47 <br/>
 * 
 * @author xuejianxin
 */

@Component
public class JsonProducer {

	private static org.slf4j.Logger log = org.slf4j.LoggerFactory.getLogger(JsonProducer.class);

	@Autowired
	private RabbitTemplate rabbitTemplate;

	// =========================queueTest1===============================
	@Bean
	public Queue queueTestJson() {
		return new Queue("queueTestJson", false /* 不持久化 */);
	}

	// 简单模式是最简单的消息模式，它包含一个生产者、一个消费者和一个队列。生产者向队列里发送消息，消费者从队列中获取消息并消费。
	public void sendTestJson(Demo demo) {
		rabbitTemplate.convertAndSend("queueTestJson",demo);
		log.info("sendTestJson demo={}", demo);
	}
	// =========================queueTest1===============================

	
}
